package cc.shacocloud.redis.study.queue.message;

import java.util.List;

/**
 * 消息队列生产者
 */
public interface MessageQueueProducer {

    /**
     * 添加一条消息至队列中
     *
     * @param data 数据
     * @return 消息唯一id
     */
    default String addMessage(byte[] data) {
        return batchAddMessage(data).get(0);
    }

    /**
     * 批量添加消息
     *
     * @param dataArr 数据集
     * @return 消息唯一id，顺序与保存一致
     */
    List<String> batchAddMessage(byte[]... dataArr);

}
